package cn.dglydrpy.study.j2ee.kafka.producer;

/**
 * 先创建主题  再运行
./kafka-topics.sh --zookeeper 192.168.80.131:2181/myKafka --create --topic topic_2 --partitions 3 --replication-factor 1
 * @author LY_飘涯
 *
 */
public class ProducerMain {
    public static void main(String[] args){
        Thread thread = new Thread(new ProducerHandler("hello "));
        thread.start();
    }
}